package com.chis.flink;

import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

public class KafkaPrintTest<String> extends RichSinkFunction<String> {
    public void open(Configuration parameters) throws Exception {

    }

    public void invoke(String ss) {
        System.out.println("=======start=========");
        System.out.println(ss);
        System.out.println("========end==========");
        
    }
}
